package com.syg.WebSocket;

//import javax.websocket.Session;
//import javax.websocket.server.ServerEndpoint;
import java.util.concurrent.CopyOnWriteArraySet;

/**
 * @ServerEndpoint 注解是一个类层次的注解, 它的功能主要是将目前的类定义成一个websocket服务端,
 * 注解的值将被用于监听用户连接的终端访问url地址,客户端可以通过这个url来连接到WebSocket服务端
 */
//@ServerEndpoint("/webSocket")
public class WebSocketTest {
    //静态变量,用来记录当前在线连接数,所以应该把它设计成线程安全的
//    private static int onlineCount = 0;
//
//    //concurrent包的线程安全set,用来存放每个客户端对应的Socket对象,若要实现服务端与单一客户端通信的话,可以使用Map来存放,其中key可以为用户标识
//    private static CopyOnWriteArraySet<WebSocketTest> webSocketSet = new CopyOnWriteArraySet<>();
//
//    //与某个客户端的连接会话,需要通过它来给客户端发送数据
//    private Session session;
//
//    /**
//     * 连接建立成功调用的方法
//     * @param session 可选的参数。session为与某个客户端的连接会话,需要通过它来给客户端发送数据
//     */
//    public void onOpen(Session session) {
//        this.session = session;
//        webSocketSet.add(this);//加入set中
//
//    }
}
